package com.inspinia.base.mq;

import org.apache.kafka.clients.consumer.ConsumerRecord;

/**
 * 消费者线程的回调函数
 * Created by veblen on 16/5/3.
 */
public interface ConsumerCallback {

    /**
     * 处理回调
     */
     void process(ConsumerRecord<String, String> records);

}
